//package com.xiao.message.rabbitmq.config;
//
//import com.xiao.foundation.constant.RabbitMqConstant;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.*;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//
///**
// * @ClassName RabbitmqConfig
// * @Description
// * @Author yanghuan
// * @Date 2020/11/24 10:56
// * @Version 1.0
// **/
//@Slf4j
//@Configuration
//public class RabbitmqConfig {
//
//	/**
//	 * 短信消息队列
//	 */
//	@Bean
//	public Queue smsQueue() {
//		return new Queue("UMS_SMS_QUEUE", true);
//	}
//
//	/**
//	 * 短信消息交换机
//	 */
//	@Bean
//	public CustomExchange smsExchange() {
//		return new CustomExchange("ums.sms.exchange", "direct", true, false);
//	}
//
//	/**
//	 * 短信队列绑定
//	 *
//	 * @param smsQueue    队列
//	 * @param smsExchange 短信交换机
//	 */
//	@Bean
//	public Binding smsBinding(Queue smsQueue, CustomExchange smsExchange) {
//		return BindingBuilder.bind(smsQueue).to(smsExchange).with("UMS_SMS_QUEUE_KEY").noargs();
//	}
//
//	@Bean
//	public FanoutExchange fanoutExchange() {
//		return new FanoutExchange("exchange.fanout.message.notification");
//	}
//
//	@Bean
//	public FanoutExchange mergeUserExchange() {
//		return new FanoutExchange(RabbitMqConstant.EXCHANGE_FANOUT_TRANSACTION_MERGE_USER, true, false);
//	}
//}
